75797d1d08393da3a74feda53977da7a20d346f8,cdap-data-fabric/src/main/java/co/cask/cdap/data/stream/service/LocalStreamService.java,LocalStreamService,runOneIteration,#,85

Before Change


      Aggregator aggregator = aggregators.get(streamSpec.getName());
      if (aggregator == null) {
        // First time that we see this Stream here
        aggregator = new Aggregator(streamSpec.getName(), 0);
        aggregators.put(streamSpec.getName(), aggregator);
      }
      aggregator.checkAggregatedSize();
    }

After Change


      StreamSizeAggregator streamSizeAggregator = aggregators.get(streamSpec.getName());
      if (streamSizeAggregator == null) {
        // First time that we see this Stream here
        streamSizeAggregator = createSizeAggregator(streamSpec.getName(), 0);
      }
      streamSizeAggregator.checkAggregatedSize();
    }